package concurrency

// mod的功能
// 1 根据协议id，获取处理请求的并发模型和对应的handler
// 2 通过 distributor 方法，将来的协议和处理生成job 放入对应的队列
type Concurrency struct {
}

// 获取并发模块
func NewConcurrency(maxWorkers int) *Concurrency {
	p := &Concurrency{}
	return p
}

// 将自己已有的任务队列，增加某一类型的任务队列管理中
